from common.variables import consider_bfnames, consider_symbols, TimeFrameType
from datetime import datetime
from trade.data.add_factors import add_batch_factors_dag


def main():
    timeframe: TimeFrameType = "1m"
    add_batch_factors_dag(
        consider_bfnames,
        [],
        consider_symbols,
        start=datetime(2024, 1, 1, 1).timestamp() * 1000,
        end=datetime(2024, 1, 5, 1).timestamp() * 1000,
        timeframe=timeframe,
        max_part=1000,
        n_jobs=6,
        verbose=10,
    )


if __name__ == "__main__":
    main()
